#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
# Copyright (c) 2021-present, sun-shine cloud, Inc.
# All rights reserved.
# Author：  xiaobo
# Date：    2021-04-21
# 对于RTMP的协议进行pytho的实现 ； 
# 目的是实现对于视频流的分析
# 1、完成rtmp直播流的连接；
# 2、分析流的信息
# 3、分析网络信息
# 4、判断流的质量；
import socket
from rtmpStream import rtmpStream
import threading
import rtmplog

def rtmpThread(client, addr):
    rtmp = None
    rtmp = rtmpStream(client, addr)
    rtmp.handle_Rtmp_Stream()

s = socket.socket()  # 创建 socket 对象
host = socket.gethostname() # 获取本地主机名
port = 1935                # 设置端口
s.bind((host, port))        # 绑定端口
s.listen()                 # 等待客户端连接

while True:
    client, addr = s.accept()     # 建立客户端连接
    rtmplog.logger.debug("有一个新的连接！")
    threading.Thread(target=rtmpThread,args=(client, addr)).start()
    # rtmpthread = threading.Thread(target=rtmpThread,args=(client, addr))
    # rtmpthread.start()
